热门标签 | HotTags
当前位置:  开发笔记 > 编程语言 > 正文

市面|数目_微信小程序|基于小程序+C#制作一个聊天系统

篇首语:本文由编程笔记#小编为大家整理,主要介绍了微信小程序|基于小程序+C#制作一个聊天系统相关的知识,希望对你有一定的参考价值。

篇首语:本文由编程笔记#小编为大家整理,主要介绍了微信小程序|基于小程序+C#制作一个聊天系统相关的知识,希望对你有一定的参考价值。




此文主要基于小程序+C#使用WebSocket制作一个聊天系统,基本实现小程序与服务端的聊天功能。用小程序自带的客服功能只能绑定微信且一对一沟通,接入市面上成熟的即时通讯预算又略显不足,干脆自己开发一个也能应对简单的业务场景。







    • 实现流程
      • 1、服务端
        • 1.1、项目创建
        • 1.2、设计界面
        • 1.3、服务端功能实现

      • 2、小程序
        • 2.1、小程序创建
        • 2.2、页面设计
        • 2.3、消息接收
        • 2.4、消息发送





实现流程


1、服务端


1.1、项目创建



  1. 打开Visual Studio,右侧选择创建新项目。



  1. 搜索框输入winform,选择windows窗体应用,填写对应的保存路径点击下一步,创建成功后如下图。



1.2、设计界面



  1. 在工具箱拖拽出lable文本标签修改其text属性填充标题。



  1. 拖拽textbox控件到窗体上用于输入所监听的端口号及发送的文本信息等。



  1. 接下来依次拖入button控件及listview控件实现按钮及消息面板样式。


1.3、服务端功能实现



  1. 实现websocket服务端启动功能。



双击button按钮,会生成对应的按钮事件,在事件代码中先获取端口号文本框输入的值是否正确。


int port = 9000;
if (textBox_port.Text == string.Empty)

MessageBox.Show("请填写端口", "系统提示", MessageBoxButtons.OK, MessageBoxIcon.Information);
return;

try

port = Convert.ToInt32(textBox_port.Text.Trim());

catch

MessageBox.Show("请填写正确的端口", "系统提示", MessageBoxButtons.OK, MessageBoxIcon.Information);
return;



在点击后,将按钮禁用,避免用户重复点击的同时开启服务端。


try

var result = _server.Open(port, "DIS");
if (result)

this.toolStripLabel_event.Text = "启动成功";
this.toolStripLabel_event.ForeColor = Color.Green;
this.toolStripLabel1.Text = "监听端口:" + port.ToString();
WSocketServer._Logger.Info("服务器启动成功");

else

this.toolStripLabel_event.Text = "启动失败";
this.toolStripLabel_event.ForeColor = Color.Red;
this.toolStripLabel1.Text = "监听端口:" + port.ToString();
button_StartListen.Enabled = true;
button_StopListen.Enabled = false;
button_Send.Enabled = false;
WSocketServer._Logger.Error("服务器启动失败");


catch (Exception ex)

WSocketServer._Logger.Error("服务器启动失败:"+ ex.ToString());



实现开启服务端的方法,这里需要对websocket的各项信息进行配置。


this.WebSocket = new WebSocketServer();
var serverConfig = new ServerConfig

Name = serverName,
MaxConnectionNumber = 10000, //最大允许的客户端连接数目,默认为100。
Mode = SocketMode.Tcp,
Port = port, //服务器监听的端口。
ClearIdleSession = false, //true或者false, 是否清除空闲会话,默认为false。
ClearIdleSessionInterval = 120,//清除空闲会话的时间间隔,默认为120,单位为秒。
ListenBacklog = 10,
ReceiveBufferSize = 64 * 1024, //用于接收数据的缓冲区大小,默认为2048。
SendBufferSize = 64 * 1024, //用户发送数据的缓冲区大小,默认为2048。
KeepAliveInterval = 1, //keep alive消息发送时间间隔。单位为秒。
KeepAliveTime = 60, //keep alive失败重试的时间间隔。单位为秒。
SyncSend = false
;
SocketServerFactory socketServerFactory = null;
//开启wss 使用证书
if (isUseCertificate)

serverConfig.Security = serverSecurity;
serverConfig.Certificate = new SuperSocket.SocketBase.Config.CertificateConfig

StoreName = serverStoreName,
StoreLocation = System.Security.Cryptography.X509Certificates.StoreLocation.LocalMachine,
Thumbprint = serverThumbprint
;
socketServerFactory = new SocketServerFactory();



  1. 实现消息发送功能。



双击发送按钮,获取客户端网络节点号向其发送数据并将发送的文本填充至消息面板。


//客户端网络节点号
string remoteEndPointStr = session.RemoteEndPoint.ToString();
if (remoteEndPointStr == s)

try

ReceiveData sendData = new ReceiveData();
//发送数据
sendData.User = "guest";
sendData.Type = "msg";
sendData.Msg = textBox_msg.Text.Trim();
sendData.SendTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
_server.SendMessage(session, JsonConvert.SerializeObject(sendData));
this.BeginInvoke(addListView, "guest", JsonConvert.SerializeObject(sendData));
MessageBox.Show("发送成功", "系统提示", MessageBoxButtons.OK, MessageBoxIcon.Information);
return;

catch (Exception ex)

WSocketServer._Logger.Error(ex.ToString());
MessageBox.Show(ex.ToString(), "系统提示", MessageBoxButtons.OK, MessageBoxIcon.Information);
return;




  1. 实现消息监听功能,接收来自客户端的数据并进行展示。

///


/// 接收到的数据
///

/// session
/// value
private void Server_MessageReceived(SuperWebSocket.WebSocketSession session, string rData)

//IP地址
string ipAddress_Receive = session.RemoteEndPoint.ToString();
if (rData.Equals(""))

//空数据不返回服务器信息
return;

try

//接收到客户端链接发送的东西
ReceiveData receiveData &#61; JsonConvert.DeserializeObject<ReceiveData>(rData);
receiveData.SendTime &#61; DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
switch (receiveData.Type)

case "HeartBeat":
//心跳
//发送客户端连接成功信息
//_server.SendMessage(session, "HeartBeat");
break;
default:
//返回用户发送数据
_server.SendMessage(session, JsonConvert.SerializeObject(receiveData));
break;


catch

WSocketServer._Logger.Error("接收异常数据:" &#43; rData);
//错误数据不反回服务器信息
return;

if (MsgFalg)

//服务端显示客户端发送接受信息
this.BeginInvoke(addListView, ipAddress_Receive, rData);



2、小程序


2.1、小程序创建



  1. 访问微信公众平台&#xff0c;点击账号注册。



  1. 选择小程序&#xff0c;并在表单填写所需的各项信息进行注册。




  1. 在开发管理选择开发设置&#xff0c;将AppID及AppSecret复制出来进行存储。



  1. 下载安装微信web开发者工具并创建一个新的项目&#xff0c;填入上图所复制的AppId。



2.2、页面设计



  1. 页面上根据发送人判断消息在哪边展示&#xff0c;同时还需要提供一个文本框以及按钮实现发送功能。

<view class&#61;"cu-chat" id&#61;"j_page">
<view class&#61;"cu-item item.User&#61;&#61;&#39;&#39;?&#39;self&#39;:&#39;&#39;" wx:for&#61;"chatData">
<view class&#61;"cu-avatar radius" style&#61;"background-image:url(../../image/cat.jpg)" wx:if&#61;"item.User&#61;&#61;&#39;guest&#39;"></view>
<view class&#61;"main">
<view class&#61;"content shadow item.User&#61;&#61;&#39;&#39;?&#39;bg-green&#39;:&#39;&#39;">
<text>item.Msg</text>
</view>
</view>
<view class&#61;"cu-avatar radius" style&#61;"background-image:url(../../image/fm3.jpg)" wx:if&#61;"item.User&#61;&#61;&#39;&#39;"></view>
<view class&#61;"date">item.SendTime</view>
</view>
</view>


  1. 通过文本框的blur事件获取用户所输入的内容。

formMsg(e)
this.setData(
content: e.detail.value.trim()
)
,

2.3、消息接收



  1. 在js的onload事件中创建websocket的连接&#xff0c;同时监听来自服务端的消息&#xff0c;端口号可以改成配置型。

let that &#61; this;
socket &#61; wx.connectSocket(
url: &#39;ws://localhost:9000/&#39;,
success: res &#61;>
//console.info(&#39;创建连接成功&#39;);

);
// console.info(socket);
//事件监听
socket.onOpen(function ()
//console.info(&#39;连接打开成功&#39;);
);
socket.onClose(function ()
//console.info(&#39;连接关闭成功&#39;);
);
socket.onError(function ()
console.info(&#39;连接报错&#39;);
);
//服务器发送监听
socket.onMessage(function (e)
console.info(JSON.parse(e.data));
var info &#61; JSON.parse(e.data);
that.setData(
chatData: that.data.chatData.concat(info)
);
// that.setData(chatData:list);
);


  1. 在监听的回调中&#xff0c;将服务端发送的文本进行打印可以看到效果如下图。




  1. 根据其格式将数据在页面上进行渲染&#xff0c;效果如下。


2.4、消息发送



  1. 发送按钮绑定自定义函数&#xff0c;获取文本框中用户输入的值&#xff0c;并通过websocket的内置函数将数据进行传输&#xff0c;这样服务端就能对数据进行接收展示。

wx.sendSocketMessage(
data: info,
success: function (res)
,
fail: function (res)


)



有兴趣的小伙伴可以在文章基础上进行拓展&#xff0c;可以增加例如群发、文件、图片发送等更加实用的功能。



推荐阅读
  • 利用jstack进行死锁检测与线程堆栈分析
    本文介绍了如何使用jstack工具进行Java应用中的死锁检测及高CPU使用率线程的堆栈分析,帮助开发者快速定位并解决性能瓶颈。 ... [详细]
  • 本文详细介绍了Java中org.neo4j.helpers.collection.Iterators.single()方法的功能、使用场景及代码示例,帮助开发者更好地理解和应用该方法。 ... [详细]
  • 本文将介绍如何编写一些有趣的VBScript脚本,这些脚本可以在朋友之间进行无害的恶作剧。通过简单的代码示例,帮助您了解VBScript的基本语法和功能。 ... [详细]
  • 技术分享:从动态网站提取站点密钥的解决方案
    本文探讨了如何从动态网站中提取站点密钥,特别是针对验证码(reCAPTCHA)的处理方法。通过结合Selenium和requests库,提供了详细的代码示例和优化建议。 ... [详细]
  • 本文详细介绍了网络存储技术的基本概念、分类及应用场景。通过分析直连式存储(DAS)、网络附加存储(NAS)和存储区域网络(SAN)的特点,帮助读者理解不同存储方式的优势与局限性。 ... [详细]
  • 深入解析Java枚举及其高级特性
    本文详细介绍了Java枚举的概念、语法、使用规则和应用场景,并探讨了其在实际编程中的高级应用。所有相关内容已收录于GitHub仓库[JavaLearningmanual](https://github.com/Ziphtracks/JavaLearningmanual),欢迎Star并持续关注。 ... [详细]
  • Win10 UWP 开发技巧:利用 XamlTreeDump 获取 XAML 元素树
    本文介绍如何在 Win10 UWP 开发中使用 XamlTreeDump 库来获取和转换 XAML 元素树为 JSON 字符串,这对于 UI 单元测试非常有用。 ... [详细]
  • Java WebSocket 实时通信服务端实现
    本文介绍了一个基于Java的WebSocket实时通信服务端代码示例,包括客户端连接管理、消息接收与分发等功能。 ... [详细]
  • 经过一段时间的学习与实践,我已经使用D3.js完成了一些项目。鉴于中文D3教程稀缺,而英文资料虽丰富却对英语水平有一定要求,特此撰写一系列D3实战文章,旨在通过具体案例(如统计数据可视化、地图信息展示等)分享D3的使用技巧,促进技术交流。 ... [详细]
  • 如何在窗口右下角添加调整大小的手柄
    本文探讨了如何在传统MFC/Win32 API编程中实现类似C# WinForms中的SizeGrip功能,即在窗口的右下角显示一个用于调整窗口大小的手柄。我们将介绍具体的实现方法和相关API。 ... [详细]
  • SQLite 动态创建多个表的需求在网络上有不少讨论,但很少有详细的解决方案。本文将介绍如何在 Qt 环境中使用 QString 类轻松实现 SQLite 表的动态创建,并提供详细的步骤和示例代码。 ... [详细]
  • 射频系统中IM3、IIP3、OIP3、增益和P1dB的关系解析
    本文探讨了噪声系数与非线性失真对射频系统性能的影响,详细分析了IM3、IIP3、OIP3、增益(G)和1dB压缩点(P1dB)之间的关系,并提供了相关公式和图表解释。 ... [详细]
  • 本文探讨了将类成员属性设置为私有的重要性,并通过具体代码示例展示了如何实现对这些属性的有效控制。私有成员属性有助于增强数据的安全性和完整性,确保只有经过验证的数据才能被修改。 ... [详细]
  • 深入解析TCP/IP五层协议
    本文详细介绍了TCP/IP五层协议模型,包括物理层、数据链路层、网络层、传输层和应用层。每层的功能及其相互关系将被逐一解释,帮助读者理解互联网通信的原理。此外,还特别讨论了UDP和TCP协议的特点以及三次握手、四次挥手的过程。 ... [详细]
  • 本文介绍了如何在Python中使用多元核密度估计(KDE)并将其结果在3D空间中进行可视化。通过利用`scipy`库中的`gaussian_kde`函数和`matplotlib`或`mayavi`库,可以有效地展示数据的密度分布情况。 ... [详细]
author-avatar
hlfk77136
这个家伙很懒,什么也没留下!
PHP1.CN | 中国最专业的PHP中文社区 | DevBox开发工具箱 | json解析格式化 |PHP资讯 | PHP教程 | 数据库技术 | 服务器技术 | 前端开发技术 | PHP框架 | 开发工具 | 在线工具
Copyright © 1998 - 2020 PHP1.CN. All Rights Reserved | 京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有